from kafka import KafkaConsumer


# 2、没有ssl认证
kafkaConsumer = KafkaConsumer(
    '5d8d5a76201d41638e9075a1e6b2d55b__rt_data_base_huangpu',
    bootstrap_servers='120.48.177.139:8397',
                              )

def start_consumer():
    for msg in kafkaConsumer:
        # print('接收到的信息为：',msg)
        print("转换后的value：", msg.value.decode())


if __name__ == '__main__':
    start_consumer()
